package com.demo.commons;

/**
 * @author shenguangyang
 */
public interface MqCons {
    // 工作队列模式
    String WORK_QUEUE = "work.queues";


    String EMAIL_QUEUE = "EMAIL_QUEUE";
    String EMAIL_EXCHANGE = "EMAIL_EXCHANGE";

    /**
     * 死信队列演示
     */
    String DEAL_BIZ_QUEUE = "deal.biz.queue";
    String DEAL_BIZ_EXCHANGE = "deal.biz.exchange";
    String DEAL_QUEUE = "deal_queue";
    String DEAL_EXCHANGE = "deal_exchange";

    /**
     * 测试ack的
     */
    String ACK_QUEUE = "ack.queue";
    String ACK_EXCHANGE = "ack.exchange";

    /**
     * (订单超时)
     */
    String ORDER_CLOSE_QUEUE01 = "order.close.queue01";
    String ORDER_CLOSE_EXCHANGE01 = "order.close.exchange01";
    String ORDER_DEAD_QUEUE01 = "order.dead.queue01";
    String ORDER_DEAD_EXCHANGE01 = "order.close.dead.exchange01";

    String ORDER_CLOSE_QUEUE02 = "order.close.queue02";
    String ORDER_CLOSE_EXCHANGE02 = "order.close.exchange02";

    /**
     * log消息队列, 主要测试根据不用的路由可发送到不同的队列中
     */
    String LOG_ERROR_QUEUE = "log.error.queue";
    String LOG_ERROR_ROUTING_KEY = "log.queue.error.*";
    String LOG_INFO_QUEUE = "log.info.queue";
    String LOG_INFO_ROUTING_KEY = "log.queue.info.*";
    String LOG_EXCHANGE = "log.exchange";

    /**
     * 测试具有备份交换机的交换机
     */
    String CONFIRM_EXCHANGE = "confirm.exchange";
    String CONFIRM_QUEUE = "confirm.queue";
    String BACKUP_EXCHANGE = "backup.exchange";
    String BACKUP_QUEUE = "backup.queue";
    String WARNING_QUEUE = "warning.queue";


    String BIZ_ERROR_QUEUE = "biz.error.queue";
    String BIZ_ERROR_KEY = "biz.error.key";

    String BIZ_ERROR_EXCHANGE = "biz.error.exchange";
}
